package com.link.base.microinterface.cdcconsumer;

import com.alibaba.fastjson.JSONObject;
import com.link.base.microinterface.core.BaseClients;
import com.link.microservice.config.LinkFeignClientConfig;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;

/**
 * DMP消费者 Feign Client
 *
 * @author 曲元涛
 * @date 2020/3/10 12:38
 */
@FeignClient(name = "link-cdc", path = "/dmp/cdcPubConsumer", configuration = LinkFeignClientConfig.class)
public interface CdcPubConsumerClient extends BaseClients {

    /**
     * 传入HBase表名以及统一消费者ID查询业务数据
     *
     * @author 曲元涛
     * @date 2020/3/10 12:45
     * @param requestPayload 请求参数
     */
    @PostMapping(value = "queryComInfoByPage")
    JSONObject queryComInfoByPage(JSONObject requestPayload) throws Exception;
}
